# 查询
# 数据库
from pymysql import Connection
conn = None
cursor = None
# 连接数据库
def conn_mysql():
    # 获取mysql数据库连接
    conn = Connection(
        host="192.168.215.210",  # 主机名（IP地址）
        port=3306,  # 端口
        user='root',  # 用户名
        password='123456',  # 密码
        charset="utf8"  # 编码
    )
    # 获取游标
    cursor = conn.cursor()
    return conn, cursor
# 添加一条数据
def insert_data():
    # database="test" # 默认连接的数据表 如果在创建连接时选择了数据表就不需要再选择
    # 选择数据库
    conn.select_db("test")
    # 使用游标对象执行sql语句
    cursor.execute("insert into student (uname,age,sex) values('姜婉云',25,'女')")
    conn.commit()
# 删除数据
def del_data():
    # database="test" # 默认连接的数据表 如果在创建连接时选择了数据表就不需要再选择
    # 选择数据库
    conn.select_db("test")
    # 使用游标对象执行sql语句
    cursor.execute("delete from student where id = 11")
    conn.commit()
# 修改数据
def update_data():
    # database="test" # 默认连接的数据表 如果在创建连接时选择了数据表就不需要再选择
    # 选择数据库
    conn.select_db("test")
    # 使用游标对象执行sql语句
    cursor.execute("update student set age = 20 where id = 10")
    conn.commit()
# 关闭连接
def conn_close():
    global conn
    conn.close()
if __name__ == '__main__':
    try:
        # 获取连接和游标
        conn, cursor = conn_mysql()
        if conn and cursor:
            print("数据库连接正常")
            insert_data()
    except:
        print("数据库关闭异常")
    else:
        print("操作成功")
    finally:
        print("数据库关闭")
        conn_close()



